package com.bobo.gmall.realtime.test;

import com.alibaba.fastjson.JSON;
import com.bobo.gmall.realtime.bean.TableProcess;

public class testDemo {

    public static void main(String[] args) {
        String jsonStr = "{\"operate_type\":\"insert\",\"sink_type\":\"kafka\",\"sink_table\":\"dim_base_trademark\",\"source_table\":\"base_trademark\",\"sink_columns\":\"id,tm_name\"}";
        TableProcess test = JSON.parseObject(jsonStr, TableProcess.class);
        System.out.println(test);
    }
}
